// import {of} from 'rxjs';

class Observable {
    constructor(private _subscribe) {
    }
    //订阅方法
    subscribe(observer){
        return this._subscribe(observer);
    }
}

// 定义一个of函数。用于创建包含指定值的可观察对象
function of(...values){
    return new Observable((observer)=>{
        values.forEach(value=>{
            observer.next(value)
        })
        observer.complete();
    })
}

//of 创建可观察对象的函数，他接受任意数量的参数，并将这些参数作为数据项发出
of(1,2,3).subscribe({
    next:console.log,
    error:console.error,
    complete:()=>{
        console.log('success')
    }
})
